package com.yanqu.road.thinkdata;

import java.util.List;
import java.util.Map;
import java.util.Queue;

public interface ConsumerQueueOperate {

    Queue<Map<String, Object>> getQueue();

    List<Map<String, Object>> poll(int size);

    boolean cleanQueue();

}
